8160bf0535049e1e44baee889d981e5c9a1ddccb,rxbinding/src/main/java/com/jakewharton/rxbinding/widget/RadioGroupCheckedChangeEventOnSubscribe.java,RadioGroupCheckedChangeEventOnSubscribe,call,#Subscriber#,20

Before Change


      }
    };

    Subscription subscription = Subscriptions.create(new Action0() {
      @Override public void call() {
        view.setOnCheckedChangeListener(null);
      }
    });
    subscriber.add(subscription);

    view.setOnCheckedChangeListener(listener);

After Change


    this.view = view;
  }

  @Override public void call(final Subscriber<? super RadioGroupCheckedChangeEvent> subscriber) {
    checkUiThread();

    RadioGroup.OnCheckedChangeListener listener = new RadioGroup.OnCheckedChangeListener() {
      @Override public void onCheckedChanged(RadioGroup group, int checkedId) {
        if (!subscriber.isUnsubscribed()) {
          subscriber.onNext(RadioGroupCheckedChangeEvent.create(group, checkedId));
        }
      }
    };

    subscriber.add(new MainThreadSubscription() {
      @Override protected void onUnsubscribe() {
        view.setOnCheckedChangeListener(null);
      }
    });

    view.setOnCheckedChangeListener(listener);